from celery import Celery


# 为celery使用django配置文件进行设置
import os
# if not os.getenv('DJANGO_SETTINGS_MODULE'):
#     os.environ['DJANGO_SETTINGS_MODULE'] = 'dj_pre_class.settings'

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'MyBlog.settings')# 导入配置

app = Celery('myblog')  # 创建celery应用 随意命名
# app = Celery('myblog',broker='redis://127.0.0.1:6379/3',backend="redis://127.0.0.1:6379/4")  # 创建celery应用 直接配置存放地址 broker存放队列  backend存放结果

app.config_from_object('celery_tasks.celery_config')  # 导入celery配置


# 导入任务 寻找tasks任务地点
app.autodiscover_tasks(['celery_tasks.sms','celery_tasks.email' ,]) # tasks.py 不可变 文件夹名随意

